package org.smartloli.kafka.eagle.common.config;

import lombok.Data;

/**
 * @author zbc
 * @date 2022/12/14
 */
@Data
public class Cluster {
    // multi zookeeper & kafka cluster list
    String zkList;
    // zookeeper enable acl
    boolean zkAclEnable = false;
    String zkAclSchema = "digest";
    String zkAclUsername = "test";
    String zkAclPassword = "test123";

    // broker size online list
    int brokerSize = 10;

    // kafka jmx acl and ssl authenticate
    boolean jmxAcl = false;
    String jmxUser = "keadmin";
    String jmxPassword = "keadmin123";
    boolean jmxSsl = false;
    String jmxTruststoreLocation = "/Users/dengjie/workspace/ssl/certificates/kafka.truststore";
    String jmxTruststorePassword = "ke123456";

    // kafka offset storage
    String offsetStorage = "kafka";

    // kafka jmx uri
    String jmxUri = "service:jmx:rmi:///jndi/rmi://%s/jmxrmi";

    // kafka sasl authenticate
    boolean saslEnable = false;
    String saslProtocol = "SASL_PLAINTEXT";
    String saslMechanism = "SCRAM-SHA-256";
    String saslJaasConfig = "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"admin\" password=\"admin-secret\";";
    String saslClientId;
    String blacklistTopics;
    boolean saslCgroupEnable = false;
    String saslCgroupTopics = "kafka20191230,kafka20191217";

    // kafka ssl authenticate
    boolean sslEnable = false;
    String sslProtocol = "SSL";
    String sslTruststoreLocation = "/Users/dengjie/workspace/ssl/certificates/kafka.truststore";
    String sslTruststorePassword = "ke123456";
    String sslKeystoreLocation = "/Users/dengjie/workspace/ssl/certificates/kafka.keystore";
    String sslKeystorePassword = "ke123456";
    String sslKeyPassword = "ke123456";
    String sslEndpointIdentificationAlgorithm = "https";
    boolean sslCgroupEnable = false;
    String sslCgroupTopics;

}
